package per.chao.mqtt.domain.shared.store;

import io.netty.channel.Channel;
import io.netty.handler.codec.mqtt.MqttPublishMessage;
import lombok.Getter;
import lombok.Setter;

/**
 * Description: session存储对象
 *
 * @author W.Chao
 * @date 2021/6/20 12:30
 **/
@Getter
@Setter
public class SessionStore {
	private String clientId;
	private Channel channel;
	// 客户端断线时是否需要为其保留信息，重新连接时将这些消息发布
	private boolean cleanSession;
	// 遗嘱信息
	private MqttPublishMessage willMessage;
}
